<?php

include_once "ConexionBD.php";
include_once "../negocio/Vehiculo.php";

class VehiculoSQL{

    private $sql;
    

    function VehiculoSQL() {$this->sql = ConexionBD::getInstancia();}

    public function ingresarDatos(&$obj){

        $conn = $this->sql->getConexion();
	$sql="select patente from VEHICULO where patente='".$obj->getPatente()."'";
        $resultado = array();
        $resultado = $this->sql->ejecutarSql($sql);
        if (isset($resultado[0][0]) && $resultado[0][0]==$obj->getPatente()){
            //die("Error de conexion. ". pg_last_error());
            return 0;
        }
        
        if(trim($obj->getEmpresa())!="")
        $sql="insert into VEHICULO values('".$obj->getPatente()."', '".$obj->getTipo()."', '".$obj->getMarca()."', '".$obj->getModelo()."', '".$obj->getNmotor()."', '".$obj->getAnyofabric()."', '".$obj->getNchasis()."', '".$obj->getColor()."', '".$obj->getCombustible()."', null, '".$obj->getEmpresa()."' )";
        if(trim($obj->getCliente())!="")
        $sql="insert into VEHICULO values('".$obj->getPatente()."', '".$obj->getTipo()."', '".$obj->getMarca()."', '".$obj->getModelo()."', '".$obj->getNmotor()."', '".$obj->getAnyofabric()."', '".$obj->getNchasis()."', '".$obj->getColor()."', '".$obj->getCombustible()."', '".$obj->getCliente()."', null )";


        if (!pg_query( $conn , $sql )){
            //die("Error de conexion. ". pg_last_error());
            return 0;
        }
        else return 1;
        pg_close($conn);

    }

    public function modificarDatos(&$obj){

        $sql=   "UPDATE VEHICULO
                SET tipo='".$obj->getTipo()."', marca='".$obj->getMarca()."', modelo='".$obj->getModelo()."', nmotor='".$obj->getNmotor()."', anyofabric='".$obj->getAnyofabric()."', nchasis='".$obj->getNchasis()."', color='".$obj->getColor()."', combustible='".$obj->getCombustible()."', cliente='".$obj->getCliente()."', empresa='".$obj->getEmpresa()."'
                WHERE patente='".$obj->getPatente()."'";


        $conn = $this->sql->getConexion();
        if (!pg_query( $conn , $sql )){
            die("Error de conexion. ". pg_last_error());
        }
        pg_close($conn);
    }

    public function buscarDatos(&$obj){

        $sql=   "SELECT *
                FROM VEHICULO v, CLIENTE c
                WHERE v.cliente = c.rut and c.rut like '%".$obj->getRut()."%'
                AND UPPER(v.nombre) like UPPER('%".$obj->getNombres()."%')
                AND UPPER(v.apellido_p) like UPPER('%".$obj->getApellido_p()."%')
                AND UPPER(v.apellido_m) like UPPER('%".$obj->getApellido_m()."%')
                ORDER BY p.rut ASC";


        $resultado = $this->sql->ejecutarSql($sql);

        return $resultado;
    }

}

?>